package com.gitee.ed.example.reactor;

import reactor.core.publisher.SynchronousSink;

/**
 * @author hongda.li
 */
@FunctionalInterface
public interface FluxGenerator<T> {

    /**
     * 生成一个 Flux
     *
     * @param sink 同步信号生成器
     */
    long generate(long index, SynchronousSink<T> sink);
}
